//引入vuex,因为我需要使用vuex存储得到的数据
// import store from "@/store/index.js"
// 连接
let socketTask = null
// 是否主动关闭连接
let meClose = false
// 地址 写你的后端连接地址
let url = "ws://0.0.0.0:7272"
let token = null

// 开启连接
const sokcet = () => {
    // 我这个项目需要在连接的时候带token，不需要可以只写url地址
	// token = uni.getStorageSync("token") //token
	// console.log(url + token);
	//判断是否有websocet对象，有的话清空
	if (socketTask) {
		uni.closeSocket()
		socketTask = null;
	}
	// 进行连接
	socketTask = uni.connectSocket({
		url, //仅为示例，并非真实接口地址。不需要带token可以只写url地址
		success(data) {
			console.log("创建连接!");
			// 监听是否连接
			uni.onSocketOpen((res) => {
				console.log('连接成功！');
			});
		}
	});
 
	// 监听连接失败
	uni.onSocketError((err) => {
		console.log('连接失败，请检查');
		socketTask = null;
		if (!meClose) {//判断是否主动关闭进行重新连接
			setTimeout(_ => {
				sokcet(url)
			}, 5000)
		}
	})
	// 监听连接关闭close
	uni.onSocketClose((e) => {
		console.log('连接关闭！', meClose);
		socketTask = null;
		if (!meClose) {//判断是否主动关闭进行重新连接
			setTimeout(_ => {
				sokcet(url)
			}, 5000)
		}
	})
	// 监听收到信息
	uni.onSocketMessage((res) => {
		// 接收数据后回调
		console.log('服务器内容:', res);
     
	});
}
// 重新连接
const reconnect = () => {
	console.log("开始断线重连！！！！！！！！！！！");
	// 确保已经关闭后再重新打开
	uni.closeSocket()
	socketTask = '';
	console.log("重新连接中...");
	setTimeout(_ => {
		sokcet(url)
	}, 5000)
	
}
//向后端发送信息
const sendMsg = (msg) => {
	msg = JSON.stringify(msg)
	// console.log(msg);
	//通过 WebSocket 连接发送数据
	uni.sendSocketMessage({
		data: msg,
		success() {
			// console.log("成功");
		},
		fail() {
			console.log("失败");
			uni.showLoading({
				title: "加载中..."
			})
			setTimeout(() => {
				uni.hideLoading()
			}, 1000)
			if (!meClose) {
				reconnect()
			}
		},
	});
}
// 手动关闭连接
const stop = () => {
	// 主动关闭连接
	meClose = true
	uni.closeSocket({
		success() {
			console.log("手动关闭成功！");
			clearInterval(Time) //关闭定时器
			clearInterval(XTime) //关闭心跳定时器
			// 确保已经关闭
			socketTask = null;
		}
	})
}
// 导出方法
export default {
	sokcet, //连接
	stop, //关闭
	sendMsg //发送
};